package com.navinfo.tripanalysis.offline.service;

import org.apache.spark.api.java.JavaPairRDD;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.sql.SparkSession;

import java.io.Serializable;

/**
 * 瓦片与区域数据加载
 * @author 沈东生
 */
public interface LoadTileService extends Serializable{
    JavaPairRDD<Long, Integer> load(SparkSession spark, JavaSparkContext jsc);
}
